//package com.lcke.lemon.flinkcdc;
//
//import lombok.extern.slf4j.Slf4j;
//import org.apache.flink.configuration.Configuration;
//import org.apache.flink.streaming.api.functions.sink.RichSinkFunction;
//
//@Slf4j
//public class CustomSink extends RichSinkFunction<String> {
//
//    @Override
//    public void open(Configuration parameters) throws Exception {
//    }
//
//    @Override
//    public void close() throws Exception {
//    }
//
//    @Override
//    public void invoke(String value, Context context) throws Exception {
//        log.info(value);
//    }
//}
